package comm;

import com.mysql.jdbc.Statement;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map.Entry;

public class Jdbc {
	
	
//	// JDBC 驱动名及数据库 URL
//    static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
//    static final String IP = "127.0.0.1";
//    static final int PORT = 3306;
//    static final String DB = "junes";
//
//    // 数据库的用户名与密码，需要根据自己的设置
//    static final String USER = "root";
//    static final String PWD = "root";
//
//    static final String TABLES = "test";
//
//	static Connection conn = null;
//
//	public static void main(String[] args) throws Exception{
//
//		HashMap<String, Object> map = new HashMap<String, Object>();
//		map.put("name", "张上");
//		map.put("age", 25);
//		init();
//
//		System.out.println(queryList(""));
//	}
//
//	// 初始化
//	public static void init() {
//		try {
//			// 加载驱动
//			Class.forName(JDBC_DRIVER);
//			String connString = String.format("jdbc:mysql://%s:%s/%s", IP, PORT, DB);
//
//			conn = DriverManager.getConnection(connString, USER, PWD);
//			// 开始连接数据库
//			System.out.println("数据库连接成功..");
//
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//	}
//
//
//	public static int insert(HashMap<String, Object> map) throws Exception{
//
//		Statement stmt = (Statement) conn.createStatement();
//
//		String sql = "INSERT INTO "+TABLES;
//
//		String keys = "";
//		String vals = "";
//
//		for (Entry<String, Object> entry : map.entrySet()) {
//    		keys += entry.getKey() + ", ";
//    		vals += "'"+ entry.getValue() + "', ";
//		}
//
//		keys = keys.substring(0, keys.length()-2);
//		vals = vals.substring(0, vals.length()-2);
//		sql+=" ("+keys+") values("+vals+");";
//		System.out.println(sql);
//
//		stmt.close();
//
//		return stmt.executeUpdate(sql);
//	}
//
//	public static List<HashMap<String, Object>> queryList(String sql) throws Exception{
//
//		Statement stmt = (Statement) conn.createStatement();
//
//		if(sql.isEmpty()){
//			sql = "SELECT * FROM test";
//		}
//
//        ResultSet rs = stmt.executeQuery(sql);
//
//        ResultSetMetaData md = rs.getMetaData();
//
//        int columnCount = md.getColumnCount();
//
//
//        List<HashMap<String, Object>> list = new ArrayList<>();
//
//        HashMap<String, Object> map = new HashMap<String, Object>();
//        while (rs.next()) {
//            for (int i = 1; i <= columnCount; i++) {
//            	map.put(md.getColumnName(i).toString(), rs.getObject(i));
//            }
//            list.add(map);
//        }
//
//        stmt.close();
//
//		return list;
//	}
	
}
